package com.ng.common.config;

import com.influxdb.client.InfluxDBClient;
import com.influxdb.client.InfluxDBClientFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * InfluxDBConfig类用于配置InfluxDB客户端的连接。
 * 
 * 该类提供了创建InfluxDB客户端的功能，并在需要时提供访问InfluxDB的接口。
 */
@Configuration
public class InfluxDBConfig {

    @Value("${influx.url}")
    private String influxUrl; // InfluxDB URL

    @Value("${influx.token}")
    private String influxToken; // InfluxDB Token

    @Value("${influx.org}")
    private String influxOrg; // InfluxDB 组织

    @Value("${influx.bucket}")
    private String influxBucket; // InfluxDB 存储桶

    // 创建InfluxDB客户端的Bean
    @Bean
    public InfluxDBClient influxDBClient() {
        return InfluxDBClientFactory.create(influxUrl, influxToken.toCharArray(), influxOrg, influxBucket);
    } 
}
